package com.chinamobile.websocket.websocketdispatcher.common;

/**
 * @className: MessageDistributorConstants
 * @description websocket 消息分发器类型常量类
 * @author: fanzhijun
 * @date: 2024/1/22
 **/
public final class MessageDistributorConstants {
    /**
     * redis订阅通道
     */
    public static final String REDIS_WEBSOCKET_MESSAGE_CHANNEL = "websocket-send";
    /**
     * kafka订阅topic
     */
    public static final String KAFKA_WEBSOCKET_MESSAGE_TOPIC = "WEBSOCKET_MESSAGE_TOPIC"; // weosocket topic
    /**
     * 分发器配置前缀
     */
    public static final String DISTRIBUTOR_PREFIX = "ccp.websocket";
    /**
     * 基于 Redis
     */
    public static final String REDIS = "redis";

    /**
     * 基于 Kafka
     */
    public static final String KAFKA = "kafka";

}
